package cn.tramy.pinxian.wind.eventstore.query.entry

import org.springframework.data.jpa.repository.JpaRepository
import org.springframework.stereotype.Repository
import reactor.core.publisher.Flux

@Repository
interface DomainEventEntryRepository : JpaRepository<DomainEventEntry, String> {
    fun findByAggregateIdAndAggregateType(aggregateId: String, aggregateType: String): Flux<DomainEventEntry>
}